package com.ocean.system.service.impl;

import com.ocean.common.core.domain.entity.tongJi;
import com.ocean.common.utils.StringUtils;
import com.ocean.system.domain.SysFTPLogftp;
import com.ocean.system.mapper.SysPostMapper;
import com.ocean.system.service.ISysRecordService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * FTP推送日志 服务层处理
 * 
 * @author ocean
 */
@Slf4j
@Service
public class SysRecordServiceImpl implements ISysRecordService
{
    @Autowired
    private SysPostMapper postMapper;

    /**
     * 查询FTP日志集合
     * 
     * @param post 岗位信息
     * @return 岗位信息集合
     */
    @Override
    public List<SysFTPLogftp> selectRecordList(SysFTPLogftp post) {
        List<SysFTPLogftp> sysFTPLogs = postMapper.selectRecordList(post);
        for (SysFTPLogftp sysFTPLog : sysFTPLogs) {
            if(StringUtils.isNotBlank(sysFTPLog.getStatus())){
                if(sysFTPLog.getStatus().equals("0")){
                    sysFTPLog.setStatus("成功");
                }else if(sysFTPLog.getStatus().equals("2")){
                    sysFTPLog.setStatus("推送中");
                }else if(sysFTPLog.getStatus().equals("3")){
                    sysFTPLog.setStatus("已重新将文件转移至推送列表");
                }else{
                    sysFTPLog.setStatus("失败");
                }
                //sysFTPLog.setStatus(sysFTPLog.getStatus().equals("0")?"成功":"失败");
            }
        }
        return sysFTPLogs;
    }

    /**
     * 获取统计数据
     * @param time
     * @param status
     * @return
     */
    @Override
    public List<tongJi> gettjData(String time) {

            return postMapper.gettjData(time);
    }
}
